﻿#include <signal.h>
#include <iostream>
#include <string.h>
#include "XTcpClient.h"
#include <unistd.h>

using namespace std;

int main()
{
    //忽略管道信号，发送数据给已关闭的socket
    if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
    {
        return 1;
    }

    XTcpClient * prender = XTcpClient::NewInstance(10) ; 
	/*  */
	for(int i=0; i<1000; i++)
	{
		XTask * p = new XTcpTask("192.168.1.7", "9999");
		usleep(5*1000);
	    prender->addTask(p);

	}


    while(true)
    {
        sleep(1);
    }
    return 0;
}
